package com.bigdata.spark.core.rdd.builder

import org.apache.spark.rdd.RDD
import org.apache.spark.{SparkConf, SparkContext}

/**
 * @author Gerry chan
 * @version 1.0
 * 2020/12/24
 */
object Spark02_RDD_File {
  def main(args: Array[String]): Unit = {
    val sparkConf = new SparkConf()
      .setMaster("local[*]").setAppName("RDD")
    val sc = new SparkContext(sparkConf)
    //从文件中 数据作为处理的数据源
    // path路径默认以当前环境的根路径为基准，可以写绝对路径，也可以写相对路径

    val rdd: RDD[String] = sc.textFile("datas/one.txt")
    //rdd.collect().foreach(println)
    //path 路径可以式文件的具体路径，也可以目录名称
    val rdds: RDD[String] = sc.textFile("datas")
    rdds.collect().foreach(println)

    sc.stop()
  }
}
